package com.itheima.kafkademo.listener;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class ConsumerListener {

    @KafkaListener(topics = "itcast-topic")
    public void onMsg(String msg){
        System.out.println("消费到消息 ：" + msg);
    }


}
